package com.example.mqconsumer.listener;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@RocketMQMessageListener(
        consumerGroup = "my_consumer", //消费者分组
        topic = "hello"                //获取 msg 的主题,对应msg所在的主题
)
public class HelloListener implements RocketMQListener<String> {

    /**
     * 消费者会一直监听指定主题下面的消息,如果消息来了就执行 onMessage 方法
     * 参数是消息内容
     *
     * @param message 消息内容
     */
    @Override
    public void onMessage(String message) {
        log.info("消费消息: {}", message);
    }
}